/**
 * 启动socket.io服务
 */
module.exports = function (server) {
  const chatModel = require('../db/models').chatModel
  const io = require('socket.io')(server)

  //  绑定监听
  io.on('connection', function (socket) {
    console.log('新增一个客户端连接');
    // 绑定sendMsg监听
    socket.on('sendMsg', function({from, to, content}){
      console.log('服务器接收到客户端消息', {from, to, content});
      // 处理数据(保存消息)
      const chat_id = [from, to].sort().join('_')
      const create_time = Date.now()
      new chatModel({from, to, content, chat_id, create_time})
        .save(function(err, chatMsg){
          // 向客户端发送消息
          // 我 - 目标  给所有连接的人发消息
          io.emit('receiveMsg', chatMsg)

        })
        
      
    })

  })

}

